//package com.liwy3.listener;
//
//import com.alibaba.otter.canal.protocol.CanalEntry;
//import com.xpand.starter.canal.annotation.CanalEventListener;
//import com.xpand.starter.canal.annotation.ListenPoint;
//import lombok.extern.slf4j.Slf4j;
//
//import java.util.List;
//import java.util.stream.Collectors;
//
///**
// * Copyright © 2022年09月18日 北京自如信息科技有限公司. All rights reserved.
// *
// * @Prject: liwy3
// * @Package: com.liwy3.listener
// * @Description:
// * @author: Crazy4J
// * @date: 2022年09月18日 14:41
// * @version: V1.0
// */
//@Slf4j
//@CanalEventListener
//public class MyEventListener {
//
//
//    /***
//     * 自定义数据修改监听
//     * @param eventType
//     * @param rowData
//     */
//    @ListenPoint(destination = "example", schema = "tax_prod", table = {"test"}, eventType = CanalEntry.EventType.UPDATE)
//    public void onEventCustomUpdate(CanalEntry.EventType eventType, CanalEntry.RowData rowData) {
//
//        //获取用户变更的用户Id
//        String id = rowData.getAfterColumns(0).getValue();
//
//        //获取修改前的状态
//        int beforeStatus = 11;
//        for (CanalEntry.Column b : rowData.getBeforeColumnsList()) {
//            if ("status".equalsIgnoreCase(b.getName())) {
//                beforeStatus = Integer.parseInt(b.getValue());
//            }
//        }
//
//        //获取修改后的状态
//        int afterStatus = 22;
//        for (CanalEntry.Column b : rowData.getAfterColumnsList()) {
//            if ("status".equalsIgnoreCase(b.getName())) {
//                afterStatus = Integer.parseInt(b.getValue());
//            }
//        }
//
//        //对比状态变更发送mq通知
//        if (beforeStatus != afterStatus) {
//            log.info("用户表状态发生变更,用户ID:{},变更前的用户状态:{},变更后的用户状态:{} ", id, beforeStatus, afterStatus);
//            log.info("发送状态变更通知MQ");
//        }
//
//    }
//
//}
